//package thread.ThreadPool;
//
//import com.sun.xml.internal.stream.util.ThreadLocalBufferAllocator;
//
//import java.util.concurrent.BlockingQueue;
//import java.util.concurrent.LinkedBlockingQueue;
//
//class MyThreadPool2 {
//    //任务队列
//    private BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>();
//    //提交任务
//    public void submit(Runnable task) throws InterruptedException {
//        queue.put(task);
//    }
//    //构造线程池
//    public MyThreadPool2(int val) {
//        for(int i = 0; i < val; i++) {
//            Thread thread = new Thread(new Runnable() {
//                @Override
//                public void run() {
//                    try {
//                        Runnable task = queue.take();
//                        task.run();
//                    } catch (InterruptedException e) {
//                        e.printStackTrace();
//                    }
//                }
//            });
//            thread.start();
//        }
//    }
//}
//public class ThreadPool2 {
//    public static void main(String[] args) throws InterruptedException {
//        MyThreadPool2 pool = new MyThreadPool2(10);
//        pool.submit(new Runnable() {
//            @Override
//            public void run() {
//                for(int i = 0; i < 100; i++) {
//                    int num = i;
//                    System.out.println("线程: " + Thread.currentThread().getName() + "完成了任务: " + num);
//                }
//            }
//        });
//        pool.submit(new Runnable() {
//            @Override
//            public void run() {
//                for(int i = 0; i < 100; i++) {
//                    int num = i;
//                    System.out.println("线程: " + Thread.currentThread().getName() + "完成了任务: " + num);
//                }
//            }
//        });
//        pool.submit(new Runnable() {
//            @Override
//            public void run() {
//                for(int i = 0; i < 100; i++) {
//                    int num = i;
//                    System.out.println("线程: " + Thread.currentThread().getName() + "完成了任务: " + num);
//                }
//            }
//        });
//        pool.submit(new Runnable() {
//            @Override
//            public void run() {
//                for(int i = 0; i < 100; i++) {
//                    int num = i;
//                    System.out.println("线程: " + Thread.currentThread().getName() + "完成了任务: " + num);
//                }
//            }
//        });
//    }
//
//}
